# 设置队列
#   选redis作为队列
#



from celery import Celery
import os
# 1,创建celery的环境
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "meiduoproject.settings")

# 2,创建cerely实例，创建前先设置
# main参数 一般都是cerely的包名 因为包名是唯一的
app =Celery('celery_tasks')



# 3.让cerely加载 队列的配置  (写配置文件的脚本路径)
app.config_from_object('celery_tasks.config')

# 4.cerely自动检测任务
# 函数的参数是列表
# 列表的元素是 任务的包路径
app.autodiscover_tasks(['celery_tasks.sms', 'celery_tasks.email'])


# 5.消费者通过指令就可以了
# celery -A celery 实例对像的文件  worker -l info
# celery -A celery_tasks.main worker -l info